#ifndef __MQTT_CONNECT_H__
#define __MQTT_CONNECT_H__

#include "ohos_init.h"

typedef struct
{
	char* clientid;    //客户ID
	char* username;	   //用户名
	char* password;	   //密码
	char* host;		   //服务器地址
	int   port;		   //端口号
    char* subscriber;  //订阅主题
	char* publish;     //发布主题
    char* send_data;
} mqtt_msg;


void Network_mqtt_readdata(char* buf);

void Network_mqtt_senddata(mqtt_msg msg);

void Network_mqtt_subscriber(mqtt_msg mqtt_opts);

void Network_mqtt_connect(mqtt_msg mqtt_opts);
#endif
